//package com.kaikeba.config;
//
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//import org.springframework.data.redis.listener.Topic;
//
//import java.util.Queue;
//
//
///**
// * @Desc  ActiveMQ 的配置类
// * @Author li_xiaoqiang
// * @Date 2020-04-24 15:05
// */
//@Configuration
//public class ActiveMqConfig {
//    //定义存放消息的队列
//    @Bean
//    public Queue queue() {
//        return new ActiveMQQueue("ActiveMQQueue");
//    }
//
//    /**
//
//     * 发布订阅模式
//     * @return
//     */
//    @Bean
//    public Topic topic() {
//        return new ActiveMQTopic("ActiveMQTopic");
//    }
//}
